User description

问题

Listening → Processing 转移期间，recorder 的 liveness watchdog 会把"用户主动停采"误报为 EngineFailed，导致 coordinator 终止 session、胶囊弹出 `audio engine failed` 错误。

复现日志

`~/Library/Logs/OpenLess/openless.log`：

```
27.011 [recorder] cb#4250 ... <- 最后一次回调
27.054 [asr] server JSON ... <- ASR 仍在收尾
~27.5 用户松开 hotkey → end_session 调 rec.stop() → stop_flag=true + pause cpal
31.667 [ERROR] [recorder] watchdog: 录音回调已停止 4 秒，触发错误恢复
31.667 [ERROR] [coord] recorder runtime error: audio engine failed
36.244 [ERROR] [asr] error frame code=45000081 [Timeout waiting next packet]
```

同一日志里 05:51:33 有同样模式，每次都恰好在用户停止说话后 4–5 秒。

Root cause（race）

watchdog 循环原结构：

```rust
while !stop_flag.load(...) { // 顶检
thread::sleep(1s); // 长 sleep
let last = state.last_callback_time.lock(); // 不再 check stop_flag
if elapsed > 3s { fire EngineFailed; break; }
}
```

竞态时序：

1. 用户松开 hotkey → `end_session` → `rec.stop()`：先 `stop_flag.store(true)`，再 `handle.join()`
2. audio 线程从 50ms sleep 醒来 → 看到 stop_flag → `stream.pause()`（cpal callback 停止递送）
3. 此时 watchdog 还卡在 1s sleep 里
4. watchdog 醒来：旧逻辑不重检 stop_flag，直接读 `last_callback_time`，发现已 >3 秒未更新（因为 cpal 已 pause）→ 误报 EngineFailed

`Recorder::stop` 在 `end_session` 第 3 步就被调，并不是慢，但 watchdog 1s 的 sleep + 3s 的容忍阈值天然就给 race 留了 ~4s 的窗口。

修复

watchdog sleep 醒来后立即再 load 一次 stop_flag，置位则直接 break：

```rust
while !stop_flag.load(...) {
thread::sleep(1s);

// 关键：sleep 醒来后必须重新检查 stop_flag
if stop_flag.load(...) { break; }

// ...原有的 elapsed 判定

}
```

注释里写了 18 行 root cause 解释，防止后续重构时被无意识回退。

行为对比

修复保留 watchdog 在活动期捕获真故障的能力——只在 stop 流程里让它静默退出。

Test plan

• `cargo check --manifest-path openless-all/app/src-tauri/Cargo.toml` 通过
• `cargo test --manifest-path openless-all/app/src-tauri/Cargo.toml --lib recorder::` 8/8 通过（已有的 recorder 单元测试）
• 实机验证：在 macOS 上短按 hotkey → 说话 → 松开 hotkey；多重复几次，观察 `~/Library/Logs/OpenLess/openless.log` 不再出现 `watchdog: 录音回调已停止 N 秒` 日志，胶囊不再弹 `audio engine failed`
• 实机验证：拔掉/切换麦克风设备触发真故障路径，确认 watchdog 仍能正常报 EngineFailed

PR Type

Bug fix

Description

• Recheck stop_flag after watchdog sleep

• Prevent false EngineFailed on manual stop

• Preserve real audio failure detection

• Add race-condition explanation comments

Diagram Walkthrough

flowchart LR
  A["hotkey release / stop"] -- "sets" --> B["stop_flag = true"]
  C["watchdog sleep"] -- "wake up" --> D["recheck stop_flag"]
  D -- "true" --> E["exit silently"]
  D -- "false" --> F["check last callback time"]
  F -- "silent too long" --> G["EngineFailed"]